package com.py.custom.ability.kafka.producer.base;

/**
 * 生产者 接口
 *
 * @param <K>
 * @param <V>
 */
public interface ProducerProcessor<K, V> {

    ProducerResult sendMessage(V message) throws Exception;

    ProducerResult sendMessage(String topicName, V message) throws Exception;

    void close() throws Exception;
}
